package com.sh.apibackend.utils;


import com.google.gson.Gson;
import com.sh.apibackend.model.vo.QQToJMSMessage;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

/**
 * 请求邮件的消息发送到消息队列中
 * @author sh
 */
@Component
@Slf4j
public class EmailCaptchaMqUtils {

    @Resource // 自动注入 JmsTemplate 实例
    private JmsTemplate jmsTemplate;

    @Value(value = "${emailCaptchaToJMS}") // 从配置文件中注入队列名称
    private String queueName;
    public void sendQQEmailToJMS(QQToJMSMessage qqEmail) {
        if (qqEmail==null){
            throw new RuntimeException("qqEmail不能为空");
        }
        Gson gson = new Gson();
        String json = gson.toJson(qqEmail);
        jmsTemplate.convertAndSend(queueName, json);
        log.info("发送消息到消息队列:::"+ json);
    }

}
